package metrics

import "github.com/rcrowley/go-metrics"

var (
	FlowBodyStoreInputCount metrics.Counter
	FlowRecordInputCount    metrics.Counter
	FlowRankInputCount      metrics.Counter

	FlowBodyStoreCompleteCount metrics.Counter
	FlowRecordCompleteCount    metrics.Counter
	FlowRankCompleteCount      metrics.Counter
)

func InitBodyStore() {
	FlowBodyStoreInputCount = metrics.NewCounter()
	metrics.Register("flow.body_store.input.count", FlowBodyStoreInputCount)

	FlowRecordInputCount = metrics.NewCounter()
	metrics.Register("flow.record.input.count", FlowRecordInputCount)

	FlowRankInputCount = metrics.NewCounter()
	metrics.Register("flow.rank.input.count", FlowRankInputCount)

	FlowBodyStoreCompleteCount = metrics.NewCounter()
	metrics.Register("flow.body_store.complete.count", FlowBodyStoreCompleteCount)

	FlowRecordCompleteCount = metrics.NewCounter()
	metrics.Register("flow.record.complete.count", FlowRecordCompleteCount)

	FlowRankCompleteCount = metrics.NewCounter()
	metrics.Register("flow.rank.complete.count", FlowRankCompleteCount)
}
